
package com.ynet.middleground.riskmanage.mq.consumer;

import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

import com.ynet.core.log.IfpLogger;
import com.ynet.middleground.riskmanage.mq.SinkTest;

/**
 * MQ 测试专用
 * 
 * @author liulx
 */
@Component
public class SinkConsumer {

    /**
     * 生产测试专用
     * 
     * @param message 接收到的消息
     */

    @StreamListener(SinkTest.I_RISKMANAGE_TEST)
    public void inputConsumer(String message) {
        IfpLogger.info("mq", "MQ 测试，从 Binding-{}收到信息-{}", SinkTest.I_RISKMANAGE_TEST, message);
    }

}
